package f3source.s1predefinedsource;

import org.apache.flink.streaming.api.datastream.DataStreamSource;
import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;

import java.util.Arrays;
import java.util.List;


public class s12collectsource {
    public static void main(String[] args) throws  Exception {
        StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();

        env.setParallelism(1);

        List<String> coll = Arrays.asList("paid", "pend", "shipped");
        DataStreamSource<String> colls = env.fromCollection(coll);

        colls.print();

        env.execute();

    }
}
